includable / cli

const output = require('./output')

const Container = require('./containers/Container')

const autoreload = require('./plugins/Autoreload')

const pkg = require('../package.json')

const io = require('socket.io-client')

const fs = require('fs')

const tmp = require('tmp')

const path = require('path')

const chalk = require('chalk')

const moment = require('moment')

const request = require('./util').request

const child = require('./util/ChildProcess')

const Module = require('./containers/Module')

const archiver = require('archiver')

const filesize = require('file-size')

module.exports = {

  uploadFile: function (containerToken, event, path, cb, spinner) {

    var r = request(containerToken + '/fs', {

      'action': event,

      'name': path

    }, {

      'Content-Type': 'multipart/form-data'

    })

    if (event === 'add' || event === 'change' || event === 'zipBall') {

      r = r.attach('file', path)

    }

    var self = this

    return r.end(function (response) {

      if (response.body && response.body === 'Error: invalid container') {

        Container.clean()

        var func = spinner || output.err

        func('Container ' + containerToken + ' does not exist anymore. We cleaned your local environment, so that you can start with a clean container.')

        process.exit()

      }

      autoreload(containerToken, path, event)

      if (cb) {

        cb(response.body || '')

        return

      }

      if (!response.body) {

        return

      }

      if (response.body.indexOf('Error:') === 0) {

        output.err(response.body)

        return

      }

      self.logSyncMessage(response.body)

    })

  },

  logMessage: function (data, ret) {

    var message =

      chalk.bold(chalk[data.color](data.component)) + ' ' +

      data.message

    if ('time' in data) {

      if (data.time === 'now') {

        data.time = (new Date()).getTime() / 1000

      }

      message += ' ' + chalk.dim(moment(data.time * 1000).format('hh:mm:ss'))

    }

    if (ret) {

      return message

    }

    return output.log(message)

  },

  logSyncMessage: function (message, ret, component) {

    return this.logMessage({

      component: component || 'Sync',

      color: 'green',

      message: message,

      time: 'now'

    }, !!ret)

  },

  createInitialZip: function (dir, containerToken, envr, cb) {

    var self = this

    this.createZipArchive(dir, 'Sync', function (zipName, size, unlinkFn) {

      var stopSpinner = output.wait(self.logSyncMessage('Uploading initial zipball (' + size + ')', true))

      try {

        self.uploadFile(containerToken, 'zipBall', zipName, function (responseBody) {

          unlinkFn()

          if (responseBody.indexOf('OK') !== 0) {

            stopSpinner(responseBody || 'Could not connect to server (empty response)')

            process.exit()

          }

          stopSpinner(true)

          cb()

        }, stopSpinner)

      } catch (e) {

        unlinkFn()

        stopSpinner(e.message)

      }

    })

  },

  startChildProcess: function (type, callback, basePath) {

    Module.getManifest(function (manifest) {

      // Get scripts object

      var scripts = manifest.getDevOption('scripts')

      if (!scripts || typeof scripts !== 'object' || !(type in scripts)) {

        return callback ? callback(0) : false

      }

      // Cast to array if script is string

      if (typeof scripts[type] === 'string') {

        scripts[type] = [scripts[type]]

      }

      if (!(type in scripts) || !('length' in scripts[type])) {

        return callback ? callback(0) : false

      }

      var count = 0

      for (var x in scripts[type]) {

        if (!scripts[type].hasOwnProperty(x)) {

          continue

        }

        var script = scripts[type][x]

        child.run(script, callback, basePath)

        count++

      }

      return !!count

    }, basePath)

  },

  startWebSocket: function (containerToken) {

    var socket = io('http://ws.sadev.io/')

    var self = this

    socket.on('connect', function () {

      socket.emit('room', 'SADEV:' + containerToken)

      socket.emit('room', 'BROADCAST')

      socket.emit('room', pkg.name + '/' + pkg.version)

      socket.emit('clientInfo', pkg)

    })

    socket.on('log', function (data) {

      if (!('color' in data)) {

        if (data.component === 'Logger') {

          data.color = 'yellow'

        } else {

          data.color = 'blue'

        }

      }

      self.logMessage(data)

    })

    socket.on('disconnect', function () {

      socket.close()

      setTimeout(function () {

        self.startWebSocket(containerToken)

      }, 1000)

    })

    socket.open()

  }

}